package com.dtxy.data

import java.util


/**
 * Created by juice on 2015/9/2.
 */
class ServiceImpl extends CompeThrift.Iface {

  override def test(test: String): String = {
    test
  }

  override def compe(hdfsPath: String, taskNum:Int, executorMemory:String): String = {
    Compute.run(hdfsPath,taskNum,executorMemory)
  }

  override def compeWithPath(hdfsPath: String, taskNum:Int, paramsMap: util.Map[String, String]): String = {
    Compute.run(hdfsPath, taskNum, paramsMap)
  }

  override def compeWithList(jsList: util.List[String], taskNum:Int, paramsMap: util.Map[String, String]): String = {
    println("keys: "+paramsMap.keySet().toArray.toList)
    println("values: "+paramsMap.values().toArray.toList)
//    for(ks <- paramsMap.entrySet())
//    {
//      println(ks.)
//    }
    Compute.run(jsList, taskNum, paramsMap)
  }
}
